Method: Rdf4jPreparedStatement(StatementExecutor, String)

1: /*
2: * JOPA
3: * Copyright (C) 2024 Czech Technical University in Prague
4: *
5: * This library is free software; you can redistribute it and/or
6: * modify it under the terms of the GNU Lesser General Public
7: * License as published by the Free Software Foundation; either
8: * version 3.0 of the License, or (at your option) any later version.
9: *
10: * This library is distributed in the hope that it will be useful,
11: * but WITHOUT ANY WARRANTY; without even the implied warranty of
12: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13: * Lesser General Public License for more details.
14: *
15: * You should have received a copy of the GNU Lesser General Public
16: * License along with this library.
17: */
18: package cz.cvut.kbss.ontodriver.rdf4j.query;
19:
20: import cz.cvut.kbss.ontodriver.PreparedStatement;
21: import cz.cvut.kbss.ontodriver.ResultSet;
22: import cz.cvut.kbss.ontodriver.exception.OntoDriverException;
23: import cz.cvut.kbss.ontodriver.rdf4j.connector.StatementExecutor;
24: import cz.cvut.kbss.ontodriver.util.StatementHolder;
25:
26: import java.util.Objects;
27:
28: import static cz.cvut.kbss.ontodriver.util.ErrorUtils.getNPXMessageSupplier;
29:
30: public class Rdf4jPreparedStatement extends Rdf4jStatement implements PreparedStatement {
31:
32: private final StatementHolder statementHolder;
33:
34: public Rdf4jPreparedStatement(StatementExecutor executor, String statement) {
35: super(executor);
36: this.statementHolder = new StatementHolder(statement);
37:• if (statementHolder.getStatement().isEmpty()) {
38: throw new IllegalArgumentException("The statement string cannot be empty.");
39: }
40: statementHolder.analyzeStatement();
41: }
42:
43: @Override
44: public void setObject(String binding, Object value) {
45: ensureOpen();
46: Objects.requireNonNull(value, getNPXMessageSupplier("value"));
47: statementHolder.setParameter(binding, value.toString());
48: }
49:
50: @Override
51: public ResultSet executeQuery() throws OntoDriverException {
52: ensureOpen();
53: return executeQuery(statementHolder.assembleStatement());
54: }
55:
56: @Override
57: public void executeUpdate() throws OntoDriverException {
58: ensureOpen();
59: executeUpdate(statementHolder.assembleStatement());
60: }
61:
62: @Override
63: public void clearParameters() {
64: statementHolder.clearParameters();
65: }
66: }